package com.iflyun.LogsCustmerToHDFS.utils;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.rabbitmq.client.ConnectionFactory;

/**
 * 
 * @ClassName:  RabbitMQConnectionFactory   
 * @Description:自定义实现  ConnectionFactory
 * @author: wenquxing  
 * @date:   2017年8月25日 上午9:55:24   
 *
 */
public class RabbitMQConnectionFactory extends ConnectionFactory {
	
	private  Logger logger = LoggerFactory.getLogger(this.getClass());

	@Override
	public void setPassword(String password) {
//		密码进行3des解密
		try {
			password=ThreeDESUtils.des3DecodeCBC(password);
		} catch (Exception e) {
			password="";
			logger.error("解码错误:",e);
			
		}
		super.setPassword(password);
	}
	
	

}
